package xyz.hubery.stream;

import org.springframework.cloud.stream.annotation.Output;
import org.springframework.messaging.MessageChannel;

public interface Source {

    /**
     * 发送盘口数据（供前端显示
     * @return
     */
    @Output("trade-plate-out")
    MessageChannel tradePlateOut();

//    /**
//     * 发送交易完成的订单 (用于更新委托单
//     * @return
//     */
//    @Output("completed-orders-out")
//    MessageChannel completedOrdersOut();

    /**
     * 发送成交记录( 数据库新增成交记录数据
     * @return
     */
    @Output("exchange-trades-out")
    MessageChannel exchangeTradesOut();

    /**
     * 发送订单删除成功消息( 通知交易服务更新委托单状态为取消
     * @return
     */
    @Output("cancel-order-out")
    MessageChannel cancelOrderOut();


}
